package com.company.project.rocketmq;

import org.apache.rocketmq.common.message.MessageExt;
import org.springframework.stereotype.Service;
// test 测试
//@Service
public class MessageProcessor implements IMessageProcessor {

	public boolean handleMessage(MessageExt message) {

		System.out.println("用户的获取消息，进行业务处理..." + message.toString());
		
		return true;
	}

}
